package utils;

import java.util.Map;

public class KafkaSourceBuilder {
    public CustomKafkaSourceFunction buildSourceFunction(Map<String, String> config) {
        return new CustomKafkaSourceFunction(config);

    }
}
